package com.hzlx;

import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.stereotype.Component;

@Component
public class Subscriber {
    @ServiceActivator(inputChannel = "mqttInputChannel")
    public void handleMessage(String payload) {
        System.out.println("Received from PLC: " + payload);
    }
}
